const mgRecordService = require('../services/mgRecordService');
let R = require('../result/r');

/**
 * mgRecordController
 * Controller 是业务入口，由 HTTP 路由解析后调用
 * 包含攒钱记录的增删改查功能
 */
class mgRecordController {
    /**
     * 列出所有攒钱记录
     */
    async listAll(ctx) {

        const list = await mgRecordService.listAll();
        ctx.body = R.ok().data(list);
    }

    /**
     * 查询分页 +根据mg_id
     */
    async queryPage(ctx) {
        const params = ctx.request.body;
        const list = await mgRecordService.queryPage(params);
        ctx.body = R.ok().data(list);
    }

    /**
     * 查询一条数据根据id
     */
    async getOneById(ctx) {
        const one = await mgRecordService.getOneById(ctx.params.id);
        ctx.body = R.ok().data(one);
    }

    /**
     * 创建一条攒钱记录
     */
    async add(ctx) {
        const mgRecord = ctx.request.body;
        const result = await mgRecordService.create(mgRecord);
        ctx.body = R.ok("新增成功").data(result);
    }

    /**
     * 删除一条攒钱记录
     * @param ctx Koa 的上下文参数
     */
    async deleteById(ctx) {
        //console.log(ctx.params.id)
        await mgRecordService.delete(ctx.params.id);
        ctx.body = R.ok("删除成功");
    }

    async deleteBatchByIds(ctx) {
        const ids = ctx.request.body.ids;
        await mgRecordService.deleteBatchByIds(ids);
        ctx.body = R.ok("删除成功");
    }


    /**
     * 更新攒钱记录
     */
    async updateOneById(ctx) {
        const mgRecord = ctx.request.body;
        await mgRecordService.update(mgRecord);
        ctx.body = R.ok("更新成功");
    }

    async getGroupDescPrice(ctx) {
        //console.log(ctx.params.mg_id)
        let mgId = ctx.params.mg_id;
        let res = await mgRecordService.getGroupDescPrice(mgId);
        ctx.body = R.ok().data(res)
    }

    async getGroupDescDay(ctx){
        let mgId = ctx.params.mg_id;
        let res = await mgRecordService.getGroupDescDay(mgId);
        ctx.body = R.ok().data(res)
    }

}

// 导出 Controller 的实例
module.exports = new mgRecordController();
